package com.king.first.func;

import org.apache.flink.streaming.api.functions.windowing.ProcessWindowFunction;
import org.apache.flink.streaming.api.windowing.windows.TimeWindow;
import org.apache.flink.util.Collector;

class MyWindow extends ProcessWindowFunction<Object, Object, Object, TimeWindow> {

    @Override
    public void process(Object o, ProcessWindowFunction<Object, Object, Object, TimeWindow>.Context context, Iterable<Object> elements, Collector<Object> out) throws Exception {

    }
}
